package com.zhang.util;

/**
 * @title:
 * @author: zhang
 * @date: 2022/6/19 15:16
 */
public class MysqlUtil {
    public static String mysqlTableDDL(String tableName) {
        return "WITH ( " +
                "'connector' = 'jdbc', " +
                "'url' = 'jdbc:mysql://hadoop102:3306/flink_test', " +
                "'table-name' = '" + tableName + "', " +
                "'username' = 'root', " +
                "'password' = '000000', " +
                "'driver' = 'com.mysql.cj.jdbc.Driver' " +
                ")";
    }
}
